import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.test.sdk.pay.util.ConnectionUtil;

/**
 * @author 徒有琴
 */
public class SimpleSender {
    public static void main(String[] args) throws Exception {
        Connection connection = ConnectionUtil.getConnection();
        Channel channel = connection.createChannel();
        //队列名
        //是否持久化 默认不是持久化的，队列重启的时候，会清空
        //是否排外 如果设置排外true  当前队列只有创建它的连接才可以使用
        //自动删除 当最后一个消费者断开连接之后是否删除队列
        //额外参数 消息头
        channel.queueDeclare("test_queue",false,false,false,null);
        String message="hello world";
        channel.basicPublish("","test_queue",null,message.getBytes());
        channel.close();
        connection.close();
    }
}
